4996d8ffd8fe9cd56751b2daba076fe87e6220a3,fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java,AbstractCrawlerService,delete,#Consumer#,403

Before Change


                break;
            }

            final BulkRequestBuilder bulkBuilder = getClient().prepareBulk();
            for (final SearchHit searchHit : searchHits) {
                bulkBuilder.add(getClient().prepareDelete(index, type, searchHit.getId()));
            }

            final BulkResponse bulkResponse = ActionGetUtil.actionGet(bulkBuilder.execute());
            if (bulkResponse.hasFailures()) {
                throw new EsAccessException(bulkResponse.buildFailureMessage());
            }

After Change


        while (true) {
            final SearchResponse prevResponse = response;
            response = getClient()
                    .get(c -> c.prepareSearchScroll(prevResponse.getScrollId()).setScroll(new TimeValue(scrollTimeout)).execute());

            final SearchHits searchHits = response.getHits();
            if (searchHits.hits().length == 0) {